package com.highper.common.mq;

import com.alibaba.fastjson.JSONObject;
import com.highper.common.sehcma.ContextHandler;
import lombok.extern.slf4j.Slf4j;

/**
 * @Author ZhangGJ
 * @Date 2022/01/29 10:47
 */
@Slf4j
public class MessageSchema {

    public static void schema(JSONObject jsonObject) {
        log.info("start listening...");
        ContextHandler.setSchema(jsonObject.getString("schema"));
    }

}
